var express = require('express');
var router = express.Router();
let mysql = require("mysql");
let DB = require("../tools/DB")

/* GET home page. */
router.get('/', function(req, res, next) {
  res.render('index', { title: 'Express' });
});

// 操作班级表
router.get("/banji",(req,res,next)=>{
  //1) 创建连接对象
   let options = {
     host:"localhost",  //数据库服务器IP地址或域名
     port:3306,         //端口号
     user:"root",   //用户名
     password:"root",    //用户密码
     database:"ujiuye"    //要打开的数据库名字
   }
   let conn = mysql.createConnection(options);
  //2) 尝试连接对象
  conn.connect((err)=>{
    if(err){
      console.log("数据库连接失败，原因：" + err);
      return;
    }else{
      console.log("数据库连接成功" + conn.threadId);
    }
  })
  //3) 执行CRUD操作
  let sql1 = "insert into 班级(班号,班主任,班长,教室) values(?,?,?,?)";//新增数据
  let sql2 = "UPDATE 班级 SET 班长=?,班主任=? WHERE id=?";//新增数据
  let sql3 = "select * from 班级"

  conn.query(sql3,[],(err,result) => {
    //err为错误消息信息，result为成功后执行的结果（没错误err为null，有错误为对象）
    if(!err){
      console.log(result);
      res.send("数据查找成功");
    }else{
      console.log(err);
      res.send("数据查找失败" + err);
    }
  })
  //4) 断开连接
  conn.end();
})

router.get("/delstudent",async (req,res)=>{
  let {id} = req.query;

  //*****await等待数据库sql执行完成后返回的结果*****
  let a = await DB.query("delete from 学生 where id=?",[id]);
  if(a.affectedRows > 0){
    res.send("删除成功")
  }else{
    res.send("删除失败")
  }
})

router.get("/list",async (req,res)=>{
  let a = await DB.query("select id,学号,姓名,出生日期 from 学生",[])
  console.log(a);
  res.render("list.ejs",{result:a})
})

module.exports = router;
